package rabbitMQStudy;

import com.rabbitmq.client.Channel;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * Project: tobe-better-coder
 * Package: rabbitMQStudy
 *
 * @author : Mr.xu
 * @date : 2023/5/6 7:28
 */
public class Producer {

    //定义一个队列名称
    public static final String QUEUE_NAME = "hello";

    public static void main(String[] args) throws IOException, TimeoutException {


        Channel channel = CommonUtil.getChannel();

        /**
         * String queue:队列名
         * boolean durable 是否持久化，持久化的话会写到磁盘上，否则指挥保存在内存中
         *boolean exclusive 是否只提供给一个消费者消费，即是否共享消息
         * boolean autoDelete 是否自动删除 最后一个消费者断开连接后是否删除消息
         * Map<String, Object> arguments 其它参数
         */
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

//        channel.queueDeclare(QUEUE_NAME,false,true,false,null);

        String message = "hello rabbitmq";

        for (int i = 0; i < 100; i++) {
            channel.basicPublish("", QUEUE_NAME, null, (message + i).getBytes());
        }

        System.out.println("消息发送完毕");

    }
}